package com.xclink.app.service.core;

import java.io.IOException;
import java.util.Date;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.springframework.stereotype.Service;

import com.xclink.app.service.core.ReplyMessage.ProcessImageMessage;
import com.xclink.app.service.core.ReplyMessage.ProcessTextMessage;
import com.xclink.app.service.core.ReplyMessage.ProcessVideoMessage;
import com.xclink.app.service.core.ReplyMessage.ProcessVoiceMessage;
import com.xclink.app.utils.message.MessageUtil;
import com.xclink.app.utils.message.resp.TextMessage;


/**
 * @author ljp 核心服务类
 */
@Service("coreService")
public class CoreServiceImpl implements CoreService {

	/**
	 * 处理微信发来的请求（包括事件的推送）
	 */
	public String processRequest(HttpServletRequest request) {
		String respMessage = "";

		try {
			// xml请求解析
			Map<String, String> requestMap = MessageUtil.xmlToMap(request);
			// 发送方帐号（open_id）
			String fromUserName = requestMap.get("FromUserName");
			// 公众帐号
			String toUserName = requestMap.get("ToUserName");
			// 消息类型
			String msgType = requestMap.get("MsgType");
			// 消息内容
			String content = requestMap.get("Content");
			// 图片url
			String picUrl = requestMap.get("PicUrl");
			// 消息的id
			String msgId = requestMap.get("MsgId");
			// 媒体文件id
			String mediaId = requestMap.get("MediaId");
			//	缩略图的媒体id
			String thumbMediaId =requestMap.get("ThumbMediaId");
			
			TextMessage text = new TextMessage();
			text.setContent(content);
			text.setToUserName(fromUserName);
			text.setFromUserName(toUserName);
			text.setCreateTime(new Date().getTime());
			text.setMsgType("text");
			
			// 文本消息
			if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {
//				因为文本消息的业务逻辑以后可能会复杂所以单独写一个类来处理，以下类似
				ProcessTextMessage p = new ProcessTextMessage();
				respMessage= p.process(toUserName, fromUserName, content);
			}
			// 图片消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {
				// 自动回复 图片消息
				ProcessImageMessage p = new ProcessImageMessage();
				respMessage = p.process(toUserName, fromUserName, mediaId);
			}
			// 请求的是语音消息
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {
				// 自动回复 语音消息
				ProcessVoiceMessage p = new ProcessVoiceMessage();
				respMessage = p.process(toUserName, fromUserName, mediaId);
			}
			// 请求消息类型：视频
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VIDEO)) {
//				这个暂时有点问题，好像是无效的mediaId以后解决
				ProcessVideoMessage p =new ProcessVideoMessage();
				respMessage = p.process(toUserName, fromUserName, mediaId, thumbMediaId);
			}
			// 请求消息类型：小视频
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_SHORTVIDEO)) {
				ProcessVideoMessage p =new ProcessVideoMessage();
				respMessage = p.process(toUserName, fromUserName, mediaId, thumbMediaId);
			}
			// 请求消息类型：地理位置
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {
				//地理位置维度
				String location_X = requestMap.get("Location_X");
				//地理位置经度
				String location_Y = requestMap.get("Location_Y");
				//地图缩放大小
				String scale = requestMap.get("Scale");
				//地理位置信息
				String label = requestMap.get("Label");
				
				text.setContent("您的位置信息如下：经度："+location_Y+"纬度:"+location_X+"位置信息："+label+"缩放大小："+scale);
				respMessage = MessageUtil.MessageToXml(text);
			}
			// 请求消息类型：链接
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {
				text.setContent("暂不支持链接消息");
				respMessage = MessageUtil.MessageToXml(text);
			}
			// 请求消息类型：事件推送
			else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {
				String eventType = requestMap.get("Event");// 事件类型
				// 事件类型：subscribe(订阅)
				if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {
					text.setContent("欢迎关注，ljp的订阅号");
					respMessage = MessageUtil.MessageToXml(text);
				}
				// 事件类型：unsubscribe(取消订阅)
				else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {
					// 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息
				}
				// 事件类型：scan(用户已关注时的扫描带参数二维码)
				else if (eventType.equals(MessageUtil.EVENT_TYPE_SCAN)) {

				}
				// 事件类型：LOCATION(上报地理位置)
				else if (eventType.equals(MessageUtil.EVENT_TYPE_LOCATION)) {

				}
				// 自定义菜单点击事件
				else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {
					String eventKey = requestMap.get("EventKey");// 事件KEY值，与创建自定义菜单时指定的KEY值对应
					if (eventKey.equals("customer_telephone")) {			
						text.setContent("0755-86671980");
						respMessage = MessageUtil.MessageToXml(text);
					}
				}
			}

		} catch (IOException e) {
			e.printStackTrace();
		}
		return respMessage;

	}
}
